﻿#ifndef ZMQREPLYER_H
#define ZMQREPLYER_H

#include <thread>
#include "zmq.h"
typedef void * (*ReplayCallBack)(void * buf, long len, void * context);

class ZmqReplyer
{
public:
    ZmqReplyer();
    virtual ~ZmqReplyer();

	int Bind(const char* szSvrIp, int port);
	int Bind(const char * address);
	int resv(char *data,int length);
	int send(const char *data, int length);
	void reconnect();

private:
	void * m_context;
	void * m_socket;
};

#endif // ZMQREPLYER_H
